package com.study.bigdata.spark.core.rdd.operator.transform

import org.apache.spark.{SparkConf, SparkContext}

object Scala08_RDD_Operator_Transform {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setMaster("local[*]").setAppName("RDD")
    conf.set("spark.local.dir","D:\\hadoopbook\\spark\\test")
    val sc = new SparkContext(conf)

    val rdd = sc.makeRDD(1 to 10)
    // TODO 算子 - 转换 - sample
    // 抽取数据，采样数据
    // 第一个参数表示抽取数据的方式：1.抽取放回2.抽取不放回
    // 第二个参数表示：
    //    如果抽取不放回：表示每一条数据被抽取的几率
    //    如果抽取放回：参数表示每条数据希望被重复抽取的次数
    // 第三个参数：随机数种子
    //    随机数不随机，所谓的随机数，其实就是通过随机算法获取的一个数
//    val rdd1 = rdd.sample(false,0.5)
//    val rdd1 = rdd.sample(true,2)
    val rdd1 = rdd.sample(false,0.5,1)
    rdd1.collect().foreach(println)
    sc.stop()
  }

}
